//package com.example.springrabbitmqexamples.springrabbitmqexamples.mq.consumer;
//
//import com.example.springrabbitmqexamples.springrabbitmqexamples.SpringRabbitmqExamplesApplication;
//import com.example.springrabbitmqexamples.springrabbitmqexamples.config.RabbitMqConfig;
//import org.springframework.amqp.rabbit.annotation.RabbitHandler;
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.stereotype.Component;
//
///**
// * @Description
// * @Author benjamin
// * @Date 2020/7/27 17:25
// * @Version
// */
//@Component
//@RabbitListener(queues = {RabbitMqConfig.queueName})
//public class MqConsumer2 {
//
//    @RabbitHandler
//    public void consume(String s) {
//
//        System.out.println("mq consumer 2 ----->" + s);
//
////        throw new RuntimeException("异常");
//
//        SpringRabbitmqExamplesApplication.latch.countDown();
//
//
//    }
//
//}
